#ifndef __APP_MQTT_H__
#define __APP_MQTT_H__

#include <assert.h>
#include <string.h>
#include <unistd.h>

#define MQTT_SERVER "tcp://192.168.32.234:1833"
#define CLIENT_ID "Mylinux"
#define PULL_TOPIC "TEST_PULL"
#define PUSH_TOPIC "TEST_PULL"

/**
 * @brief MQTT初始化
 *
 * @return int 0:成功，-1:失败
 */
int app_mqtt_init();

/**
 * @brief MQTT注册接收回调函数
 *
 * @param recv_callback 接收回调函数
 */
void app_mqtt_registerRecvCallback(int (*recv_callback)(char *, int));

/**
 * @brief MQTT发送数据
 * 
 * @param json_str json字符串
 * @param len json字符串长度
 */
int app_mqtt_send(char *json_str, int len);

/**
 * @brief MQTT关闭
 * 
 */
void app_mqtt_close();

#endif
